4284413d2901d2772356e7b4d104739f92127137,flex/jps-plugin/src/com/intellij/jps/flex/build/JpsBuiltInFlexCompilerHandler.java,JpsBuiltInFlexCompilerHandler,scheduleInputReading,#,151
Before Change
}
private void scheduleInputReading() {
SharedThreadPool.getInstance().executeOnPooledThread(new Runnable() {
public void run() {
final StringBuilder buffer = new StringBuilder();
while (true) {
final DataInputStream dataInputStream = myDataInputStream;
if (dataInputStream != null) {
try {
buffer.append(dataInputStream.readUTF());
int index;
while ((index = buffer.indexOf("\n")) > -1) {
final String line = buffer.substring(0, index);
buffer.delete(0, index + 1);
handleInputLine(line);
}
}
catch (IOException e) {
if (dataInputStream == myDataInputStream) {
stopCompilerProcess();
}
break;
}
}
else {
break;
}
}
}
});
}
private synchronized void handleInputLine(final String line) {
After Change
}
private void scheduleInputReading() {
SharedThreadPool.getInstance().executeOnPooledThread(() -> {
final StringBuilder buffer = new StringBuilder();
while (true) {
final DataInputStream dataInputStream = myDataInputStream;
if (dataInputStream != null) {
try {
buffer.append(dataInputStream.readUTF());
int index;
while ((index = buffer.indexOf("\n")) > -1) {
final String line = buffer.substring(0, index);
buffer.delete(0, index + 1);
handleInputLine(line);
}
}
catch (IOException e) {
if (dataInputStream == myDataInputStream) {
stopCompilerProcess();
}
break;
}
}
else {
break;
}
}
});
}
private synchronized void handleInputLine(final String line) {